package com.study.flink.datastream

import org.apache.flink.streaming.api.TimeCharacteristic
import org.apache.flink.streaming.api.scala.StreamExecutionEnvironment

/**
  * Time
  * EventTime
  * IngestionTime
  * ProcessingTime
  * 生产一般用EventTime类型
  *
  * @author: stephen.shen
  * @create: 2019-05-27 17:28
  */
object FlinkTimeDemo {

  def main(args: Array[String]): Unit = {
    val env = StreamExecutionEnvironment.getExecutionEnvironment
    // 设置Time类型
    env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime)
  }
}
